package com.wutoon.etl.util;

import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @author 武兴云/72176468
 * @version 1.0
 * @date 2024/2/22 15:38
 * @description 线程池
 */
public class PowerJobThreadPool {


    // 任务每天执行不会很频繁，核心大小0，每个请求都要立刻心跳，不要队列，
    public static ThreadPoolExecutor STREAM_LOG_POOL = new ThreadPoolExecutor( 0, 30, 30, TimeUnit.SECONDS, new SynchronousQueue<>());

}
